// 职责：专门负责接收一个表名和一个参数

function execSql(sql, callback) {
    const mysql = require('mysql');

    let conn = mysql.createConnection({
        host: 'localhost',  // mysql服务器的ip地址,localhost，127.0.0.1
        port: 3306,   //mysql服务器的端口
        user: 'root',  // mysql服务器的用户
        password: '123456',  // mysql服务器的用户的密码
        database: 'hero'  //表示要连接mysql服务器的hero数据库（其他数据库就没有连上了）
    });

    conn.connect();

    conn.query(sql, (err, result) => {
        // 如果sql语句执行成功，err参数则为null
        if (err) {
            console.log('执行sql语句报错啦：' + err.message);
            callback(err, null); // 出错的回调
            return;
        }
        // sql语句执行成功之后怎么将result结构交出去呢？
        callback(null, result); //成功的回调
    })

    conn.end();
}


module.exports = execSql;


